package com.wish.g04.job.task;

import com.wish.g04.common.core.text.UUID;
import com.wish.g04.common.redis.service.RedisService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.stereotype.Component;

/**
 * 财务定时任务
 * @author tianyandong
 */
@Component
public class CaiwuTask {

    @Autowired
    private KafkaTemplate kafkaTemplate;


    /**
     * 定时任务对账 每天凌晨三点执行
     */
    public void duiZhang() {
        //发送kafka 异步调用
        String uuid = UUID.randomUUID().toString();
        kafkaTemplate.send("caiWu",uuid,"开始自动对账");
    }

}
